const mysql = require("mysql");
const mysqlConfig = require("../config/db");
// 创建连接池
const pool = mysql.createPool(mysqlConfig);

function executeSql(sql, params = []) {
    return new Promise((resolve, reject) => {
        // 创建连接
        pool.getConnection((err, conn) =>{
            if (err){
                reject(err);
            } else {
                // 执行sql
                // 防止sql注入，使用运用connection.query()的查询参数占位符
                const query = conn.query(sql, params, (err, result) => {
                    if (err) reject(err);
                    console.log("DBUtil----", result);
                    resolve(result);
                })
                // 可以打印编译之后的sql
                console.log(query.sql);

                // 关闭连接
                conn.release();
            }
        });
    })

}

module.exports = executeSql;